package com.itheima.media.mq;

import com.alibaba.fastjson.JSON;
import com.itheima.media.service.WmNewsService;
import org.apache.kafka.clients.consumer.ConsumerRecord;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

import java.util.Map;

/**
 * @Author：shenkunlin
 * @date： 2021/8/26 12:05
 * @Description：
 ***/
@Component
public class WmNewsVerifyListener {

    @Autowired
    private WmNewsService wmNewsService;

    /***
     * 风控校验结果
     */
    @KafkaListener(topics = "wmnews_save_queue",groupId = "wmnewssavegroup")
    public void verifyResult(ConsumerRecord<?,?> record){
        String result = record.value().toString();
        System.out.println("风控审核结果------->"+result);
        /***
         * 1：检测状态，true|false  true：审核通过   false：审核失败
         * 2：true：审核通过
         *     2.1 立即发布，则数据同步
         *     2.2 定时发布，定时同步
         * 3：false：审核失败
         *      直接修改状态
         */
        Map<String,Object> resultMap = JSON.parseObject(result,Map.class);
        wmNewsService.autoVerify(resultMap);
    }
}
